<?php

require 'simple_dom.php';
include 'connection.php';

function replace_class($file_contents) {
    return str_replace('class=""', 'class="prix"', $file_contents);
}

function collectData($chemin_fichier_html) {

    $html = file_get_html($chemin_fichier_html);
  
    $categorie = $html->find('#lev3 h2', 0)->innertext;    
    $query_produit = "INSERT INTO categorie (libelle) values ('$categorie');";
    if (!mysql_query($query_produit)) {
    } else {
        echo "CATEGORIE : " . $categorie . "<br/>";
    }

    $qery_id_categorie = "SELECT _id_categorie FROM categorie where libelle = '$categorie'";
    $result_cate = mysql_query($qery_id_categorie) or die(mysql_error());
    $id_cate = mysql_fetch_array($result_cate) or die(mysql_error());
    $id_categorie = $id_cate['_id_categorie'];

    $typeprod = $html->find('ul li.lev3On', 0)->innertext;
    $query_produit = "INSERT INTO  typeprod (_id_categorie,libelle) values ($id_categorie,'$typeprod');";
    if (!mysql_query($query_produit)) {       
    } else {
        echo "TYPE PRODUIT : " . $typeprod . "<br/>";
    }
    mysql_free_result($result_cate);


    $qery_id_typ = "SELECT _id_typeprod FROM typeprod where libelle = '$typeprod'";
    $result_typ = mysql_query($qery_id_typ) or die(mysql_error());
    $id_typ = mysql_fetch_array($result_typ) or die(mysql_error());
    $id_typ = $id_typ['_id_typeprod'];
    mysql_free_result($result_typ);

    $produit = $html->find('h1', 0)->innertext;
    $url = $html->find('.illus img', 0)->src;   
    $val = mysql_real_escape_string($produit);
    $search = array("\t", "\n", "\r");
    $val = str_replace($search, '', $val);
    $query_produit = "INSERT INTO produit (_id_categorie,_id_typeprod,Libelle,urlimg) values ($id_categorie,$id_typ,'$val','$url');";
    if (!mysql_query($query_produit)) {       
    } else {
        echo "PRODUIT : " . $val . "<br/>";
    }


    $qery_id_produit = "SELECT _id_produit FROM produit where Libelle = '$val'";
    $result = mysql_query($qery_id_produit) or die(mysql_error());
    $id = mysql_fetch_array($result) or die(mysql_error());
    $id_produit = $id['_id_produit'];

    mysql_free_result($result);

    foreach ($html->find('tbody tr') as $tb) {
        $produit = $tb->find('.imgProduitMdd', 0);
        if (!is_null($produit)) {
            $ens = $tb->find('.imgProduitMdd', 0)->alt;
            //$lien_image_enseigne=$produit->find('.prixMoyen img',0)->src;      
            $query_ens = "INSERT INTO enseigne (Nom) values ('$ens');";
            if (!mysql_query($query_ens)) {
            } else {
                echo "ENSEIGNE : " . $ens . "<br/>";
            }
        }
    }

    foreach ($html->find('tbody tr') as $tb) {
        $produit = $tb->find('.imgProduitMdd', 0);
        if (!is_null($produit)) {
            $ens = $tb->find('.imgProduitMdd', 0)->alt;
            $qery_id_ens = "SELECT _id_enseigne FROM enseigne where Nom = '$ens'";
            $result = mysql_query($qery_id_ens) or die(mysql_error());
            $id = mysql_fetch_array($result) or die(mysql_error());
            mysql_free_result($result);
            $id_ens = $id['_id_enseigne'];
            $prix_pourri = $tb->find('[headers="header3"]', 0)->innertext;
            $regex = '#([0-9.]+)€#U';
            preg_match($regex, $prix_pourri, $section_prix);
            $prix = $section_prix[1];
            $query_prix = "INSERT INTO prix_produit (_id_produit,_id_enseigne,prix) values ($id_produit,$id_ens,$prix)";            
            if (!mysql_query($query_prix)) {
                $query_prix_update = "UPDATE prix_produit SET prix=$prix where _id_produit=$id_produit and _id_enseigne = $id_ens";                
                mysql_query($query_prix_update) or die(mysql_error());                
            } else {
                
            }
        }
    }
   
    //$GLOBALS['cpt'] = $GLOBALS['cpt'] + 1;   
}

$dossier_depart = 'D:/dataHTML/';
$fichiers = array();
if (is_dir($dossier_depart)) {
    if ($dh = opendir($dossier_depart)) {
        while (($fic = readdir($dh)) !== false) {
            if (!in_array($fic, array('.', '..')))
                $fichiers[] = $dossier_depart . $fic;
        }
        closedir($dh);
    }
    else
        echo $dossier_depart . ' n\'est pas un repertoire valide!';
}
else
    echo $dossier_depart . ' n\'est pas un repertoire !';

sort($fichiers);

$cpt = 0;
foreach ($fichiers as $chemin_fichier) {
    collectData($chemin_fichier);
    $cpt++;    
}


ECHO 'Fini Kiri Kiri!!!! : ' . $cpt;
?>

